#include "message_buffer.h"

message_buffer::~message_buffer()
{
}

void message_buffer::push(message::msg_handle msg)
{
    queue.push(msg);
}

message::msg_handle message_buffer::pop()
{
    if (queue.empty()) {
        return NULL;
    }

    message::msg_handle msg = queue.front();
    queue.pop();
    return msg;
}

